/*     */ package com.wgcloud.controller;
/*     */ 
/*     */ import cn.hutool.json.JSONObject;
/*     */ import cn.hutool.json.JSONUtil;
/*     */ import com.github.pagehelper.PageInfo;
/*     */ import com.wgcloud.entity.CpuTemperatures;
/*     */ import com.wgcloud.entity.DeskIo;
/*     */ import com.wgcloud.entity.DeskState;
/*     */ import com.wgcloud.entity.DiskSmart;
/*     */ import com.wgcloud.service.CpuStateService;
/*     */ import com.wgcloud.service.CpuTemperaturesService;
/*     */ import com.wgcloud.service.DeskIoService;
/*     */ import com.wgcloud.service.DeskStateService;
/*     */ import com.wgcloud.service.DiskSmartService;
/*     */ import com.wgcloud.service.LogInfoService;
/*     */ import com.wgcloud.service.MemStateService;
/*     */ import com.wgcloud.service.NetIoStateService;
/*     */ import com.wgcloud.service.SysLoadStateService;
/*     */ import com.wgcloud.util.ResDataUtils;
/*     */ import com.wgcloud.util.TokenUtils;
/*     */ import com.wgcloud.util.staticvar.StaticKeys;
/*     */ import java.util.HashMap;
/*     */ import java.util.List;
/*     */ import java.util.Map;
/*     */ import javax.annotation.Resource;
/*     */ import org.apache.commons.lang3.StringUtils;
/*     */ import org.slf4j.Logger;
/*     */ import org.slf4j.LoggerFactory;
/*     */ import org.springframework.beans.factory.annotation.Autowired;
/*     */ import org.springframework.stereotype.Controller;
/*     */ import org.springframework.web.bind.annotation.RequestBody;
/*     */ import org.springframework.web.bind.annotation.RequestMapping;
/*     */ import org.springframework.web.bind.annotation.ResponseBody;
/*     */ 
/*     */ 
/*     */ 
/*     */ @Controller
/*     */ @RequestMapping({"/systemInfoOpen"})
/*     */ public class SystemInfoOpenController
/*     */ {
/*  41 */   private static final Logger logger = LoggerFactory.getLogger(com.wgcloud.controller.SystemInfoOpenController.class);
/*     */   
/*     */   @Resource
/*     */   private LogInfoService logInfoService;
/*     */   
/*     */   @Resource
/*     */   CpuStateService cpuStateService;
/*     */   
/*     */   @Resource
/*     */   DeskStateService deskStateService;
/*     */   
/*     */   @Resource
/*     */   DiskSmartService diskSmartService;
/*     */   
/*     */   @Resource
/*     */   DeskIoService deskIoService;
/*     */   
/*     */   @Resource
/*     */   CpuTemperaturesService cpuTemperaturesService;
/*     */   
/*     */   @Resource
/*     */   MemStateService memStateService;
/*     */   
/*     */   @Resource
/*     */   NetIoStateService netIoStateService;
/*     */   
/*     */   @Resource
/*     */   SysLoadStateService sysLoadStateService;
/*     */   @Autowired
/*     */   private TokenUtils tokenUtils;
/*     */   
/*     */   @ResponseBody
/*     */   @RequestMapping({"agentDiskSmartList"})
/*     */   public String agentDiskSmartList(@RequestBody String paramBean) {
/*  75 */     JSONObject agentJsonObject = (JSONObject)JSONUtil.parse(paramBean);
/*  76 */     if (!StaticKeys.LICENSE_STATE.equals("1")) {
/*  77 */       return ResDataUtils.resetErrorJson("请先升级到专业版");
/*     */     }
/*  79 */     if (!this.tokenUtils.checkAgentToken(agentJsonObject)) {
/*  80 */       logger.error("token is error");
/*  81 */       return ResDataUtils.resetErrorJson("token is error");
/*     */     } 
/*  83 */     Map<String, Object> params = new HashMap<>();
/*  84 */     if (null == agentJsonObject.get("hostname") || StringUtils.isEmpty(agentJsonObject.get("hostname").toString())) {
/*  85 */       return "";
/*     */     }
/*  87 */     params.put("hostname", agentJsonObject.get("hostname").toString());
/*     */     try {
/*  89 */       List<DiskSmart> diskSmarts = this.diskSmartService.selectAllByParams(params);
/*  90 */       return ResDataUtils.resetSuccessJson(diskSmarts);
/*  91 */     } catch (Exception e) {
/*  92 */       logger.error("agent查询根据ip查询磁盘smar列表错误", e);
/*  93 */       this.logInfoService.save("agent查询根据ip查询磁盘smar列表错误", e.toString(), "1");
/*  94 */       return ResDataUtils.resetErrorJson(e.toString());
/*     */     } 
/*     */   }
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */   
/*     */   @ResponseBody
/*     */   @RequestMapping({"agentDeskStatesList"})
/*     */   public String agentDeskStatesList(@RequestBody String paramBean) {
/* 108 */     JSONObject agentJsonObject = (JSONObject)JSONUtil.parse(paramBean);
/* 109 */     if (!StaticKeys.LICENSE_STATE.equals("1")) {
/* 110 */       return ResDataUtils.resetErrorJson("请先升级到专业版");
/*     */     }
/* 112 */     if (!this.tokenUtils.checkAgentToken(agentJsonObject)) {
/* 113 */       logger.error("token is error");
/* 114 */       return ResDataUtils.resetErrorJson("token is error");
/*     */     } 
/* 116 */     Map<String, Object> params = new HashMap<>();
/* 117 */     if (null == agentJsonObject.get("hostname") || StringUtils.isEmpty(agentJsonObject.get("hostname").toString())) {
/* 118 */       return "";
/*     */     }
/* 120 */     params.put("hostname", agentJsonObject.get("hostname").toString());
/*     */     try {
/* 122 */       List<DeskState> deskStates = this.deskStateService.selectAllByParams(params);
/* 123 */       return ResDataUtils.resetSuccessJson(deskStates);
/* 124 */     } catch (Exception e) {
/* 125 */       logger.error("agent查询根据ip查询磁盘列表错误", e);
/* 126 */       this.logInfoService.save("agent查询根据ip查询磁盘列表错误", e.toString(), "1");
/* 127 */       return ResDataUtils.resetErrorJson(e.toString());
/*     */     } 
/*     */   }
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */   
/*     */   @ResponseBody
/*     */   @RequestMapping({"agentDiskIosList"})
/*     */   public String agentDiskIosList(@RequestBody String paramBean) {
/* 140 */     JSONObject agentJsonObject = (JSONObject)JSONUtil.parse(paramBean);
/* 141 */     if (!StaticKeys.LICENSE_STATE.equals("1")) {
/* 142 */       return ResDataUtils.resetErrorJson("请先升级到专业版");
/*     */     }
/* 144 */     if (!this.tokenUtils.checkAgentToken(agentJsonObject)) {
/* 145 */       logger.error("token is error");
/* 146 */       return ResDataUtils.resetErrorJson("token is error");
/*     */     } 
/* 148 */     Map<String, Object> params = new HashMap<>();
/* 149 */     if (null == agentJsonObject.get("hostname") || StringUtils.isEmpty(agentJsonObject.get("hostname").toString())) {
/* 150 */       return "";
/*     */     }
/* 152 */     params.put("hostname", agentJsonObject.get("hostname").toString());
/*     */     try {
/* 154 */       List<DeskIo> deskIos = this.deskIoService.selectAllByParams(params);
/* 155 */       return ResDataUtils.resetSuccessJson(deskIos);
/* 156 */     } catch (Exception e) {
/* 157 */       logger.error("agent查询根据ip查询磁盘io列表错误", e);
/* 158 */       this.logInfoService.save("agent查询根据ip查询磁盘io列表错误", e.toString(), "1");
/* 159 */       return ResDataUtils.resetErrorJson(e.toString());
/*     */     } 
/*     */   }
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */   
/*     */   @ResponseBody
/*     */   @RequestMapping({"agentCpuTemperaturesList"})
/*     */   public String agentCpuTemperaturesList(@RequestBody String paramBean) {
/* 172 */     JSONObject agentJsonObject = (JSONObject)JSONUtil.parse(paramBean);
/* 173 */     if (!StaticKeys.LICENSE_STATE.equals("1")) {
/* 174 */       return ResDataUtils.resetErrorJson("请先升级到专业版");
/*     */     }
/* 176 */     if (!this.tokenUtils.checkAgentToken(agentJsonObject)) {
/* 177 */       logger.error("token is error");
/* 178 */       return ResDataUtils.resetErrorJson("token is error");
/*     */     } 
/* 180 */     Map<String, Object> params = new HashMap<>();
/* 181 */     if (null == agentJsonObject.get("hostname") || StringUtils.isEmpty(agentJsonObject.get("hostname").toString())) {
/* 182 */       return "";
/*     */     }
/* 184 */     params.put("hostname", agentJsonObject.get("hostname").toString());
/*     */     try {
/* 186 */       List<CpuTemperatures> cpuTemperatures = this.cpuTemperaturesService.selectAllByParams(params);
/* 187 */       return ResDataUtils.resetSuccessJson(cpuTemperatures);
/* 188 */     } catch (Exception e) {
/* 189 */       logger.error("agent查询根据ip查询cpu温度列表错误", e);
/* 190 */       this.logInfoService.save("agent查询根据ip查询cpu温度列表错误", e.toString(), "1");
/* 191 */       return ResDataUtils.resetErrorJson(e.toString());
/*     */     } 
/*     */   }
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */   
/*     */   @ResponseBody
/*     */   @RequestMapping({"agentNetIoStatesList"})
/*     */   public String agentNetIoStatesList(@RequestBody String paramBean) {
/* 204 */     JSONObject agentJsonObject = (JSONObject)JSONUtil.parse(paramBean);
/* 205 */     if (!StaticKeys.LICENSE_STATE.equals("1")) {
/* 206 */       return ResDataUtils.resetErrorJson("请先升级到专业版");
/*     */     }
/* 208 */     if (!this.tokenUtils.checkAgentToken(agentJsonObject)) {
/* 209 */       logger.error("token is error");
/* 210 */       return ResDataUtils.resetErrorJson("token is error");
/*     */     } 
/* 212 */     Map<String, Object> params = new HashMap<>();
/* 213 */     if (null == agentJsonObject.get("hostname") || StringUtils.isEmpty(agentJsonObject.get("hostname").toString())) {
/* 214 */       return "";
/*     */     }
/* 216 */     params.put("hostname", agentJsonObject.get("hostname").toString());
/* 217 */     if (null != agentJsonObject.get("startTime")) {
/* 218 */       params.put("startTime", agentJsonObject.get("startTime").toString());
/*     */     }
/* 220 */     if (null != agentJsonObject.get("endTime")) {
/* 221 */       params.put("endTime", agentJsonObject.get("endTime").toString());
/*     */     }
/*     */     try {
/* 224 */       PageInfo netIoStates = this.netIoStateService.selectByParams(params, agentJsonObject.getInt("page").intValue(), agentJsonObject.getInt("pageSize").intValue());
/* 225 */       return ResDataUtils.resetSuccessJson(netIoStates);
/* 226 */     } catch (Exception e) {
/* 227 */       logger.error("agent查询根据ip查询系统负载列表错误", e);
/* 228 */       this.logInfoService.save("agent查询根据ip查询系统负载列表错误", e.toString(), "1");
/* 229 */       return ResDataUtils.resetErrorJson(e.toString());
/*     */     } 
/*     */   }
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */   
/*     */   @ResponseBody
/*     */   @RequestMapping({"agentCpuStatesList"})
/*     */   public String agentCpuStatesList(@RequestBody String paramBean) {
/* 242 */     JSONObject agentJsonObject = (JSONObject)JSONUtil.parse(paramBean);
/* 243 */     if (!StaticKeys.LICENSE_STATE.equals("1")) {
/* 244 */       return ResDataUtils.resetErrorJson("请先升级到专业版");
/*     */     }
/* 246 */     if (!this.tokenUtils.checkAgentToken(agentJsonObject)) {
/* 247 */       logger.error("token is error");
/* 248 */       return ResDataUtils.resetErrorJson("token is error");
/*     */     } 
/* 250 */     Map<String, Object> params = new HashMap<>();
/* 251 */     if (null == agentJsonObject.get("hostname") || StringUtils.isEmpty(agentJsonObject.get("hostname").toString())) {
/* 252 */       return "";
/*     */     }
/* 254 */     params.put("hostname", agentJsonObject.get("hostname").toString());
/* 255 */     if (null != agentJsonObject.get("startTime")) {
/* 256 */       params.put("startTime", agentJsonObject.get("startTime").toString());
/*     */     }
/* 258 */     if (null != agentJsonObject.get("endTime")) {
/* 259 */       params.put("endTime", agentJsonObject.get("endTime").toString());
/*     */     }
/*     */     try {
/* 262 */       PageInfo cpuStates = this.cpuStateService.selectByParams(params, agentJsonObject.getInt("page").intValue(), agentJsonObject.getInt("pageSize").intValue());
/* 263 */       return ResDataUtils.resetSuccessJson(cpuStates);
/* 264 */     } catch (Exception e) {
/* 265 */       logger.error("agent查询根据ip查询系统cpu监控数据列表错误", e);
/* 266 */       this.logInfoService.save("agent查询根据ip查询系统cpu监控数据列表错误", e.toString(), "1");
/* 267 */       return ResDataUtils.resetErrorJson(e.toString());
/*     */     } 
/*     */   }
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */   
/*     */   @ResponseBody
/*     */   @RequestMapping({"agentMemStatesList"})
/*     */   public String agentMemStatesList(@RequestBody String paramBean) {
/* 280 */     JSONObject agentJsonObject = (JSONObject)JSONUtil.parse(paramBean);
/* 281 */     if (!StaticKeys.LICENSE_STATE.equals("1")) {
/* 282 */       return ResDataUtils.resetErrorJson("请先升级到专业版");
/*     */     }
/* 284 */     if (!this.tokenUtils.checkAgentToken(agentJsonObject)) {
/* 285 */       logger.error("token is error");
/* 286 */       return ResDataUtils.resetErrorJson("token is error");
/*     */     } 
/* 288 */     Map<String, Object> params = new HashMap<>();
/* 289 */     if (null == agentJsonObject.get("hostname") || StringUtils.isEmpty(agentJsonObject.get("hostname").toString())) {
/* 290 */       return "";
/*     */     }
/* 292 */     params.put("hostname", agentJsonObject.get("hostname").toString());
/* 293 */     if (null != agentJsonObject.get("startTime")) {
/* 294 */       params.put("startTime", agentJsonObject.get("startTime").toString());
/*     */     }
/* 296 */     if (null != agentJsonObject.get("endTime")) {
/* 297 */       params.put("endTime", agentJsonObject.get("endTime").toString());
/*     */     }
/*     */     try {
/* 300 */       PageInfo cpuStates = this.memStateService.selectByParams(params, agentJsonObject.getInt("page").intValue(), agentJsonObject.getInt("pageSize").intValue());
/* 301 */       return ResDataUtils.resetSuccessJson(cpuStates);
/* 302 */     } catch (Exception e) {
/* 303 */       logger.error("agent查询根据ip查询系统内存监控数据列表错误", e);
/* 304 */       this.logInfoService.save("agent查询根据ip查询系统内存监控数据列表错误", e.toString(), "1");
/* 305 */       return ResDataUtils.resetErrorJson(e.toString());
/*     */     } 
/*     */   }
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */   
/*     */   @ResponseBody
/*     */   @RequestMapping({"agentSysLoadStatesList"})
/*     */   public String agentSysLoadStatesList(@RequestBody String paramBean) {
/* 318 */     JSONObject agentJsonObject = (JSONObject)JSONUtil.parse(paramBean);
/* 319 */     if (!StaticKeys.LICENSE_STATE.equals("1")) {
/* 320 */       return ResDataUtils.resetErrorJson("请先升级到专业版");
/*     */     }
/* 322 */     if (!this.tokenUtils.checkAgentToken(agentJsonObject)) {
/* 323 */       logger.error("token is error");
/* 324 */       return ResDataUtils.resetErrorJson("token is error");
/*     */     } 
/* 326 */     Map<String, Object> params = new HashMap<>();
/* 327 */     if (null == agentJsonObject.get("hostname") || StringUtils.isEmpty(agentJsonObject.get("hostname").toString())) {
/* 328 */       return "";
/*     */     }
/* 330 */     params.put("hostname", agentJsonObject.get("hostname").toString());
/* 331 */     if (null != agentJsonObject.get("startTime")) {
/* 332 */       params.put("startTime", agentJsonObject.get("startTime").toString());
/*     */     }
/* 334 */     if (null != agentJsonObject.get("endTime")) {
/* 335 */       params.put("endTime", agentJsonObject.get("endTime").toString());
/*     */     }
/*     */     try {
/* 338 */       PageInfo cpuStates = this.sysLoadStateService.selectByParams(params, agentJsonObject.getInt("page").intValue(), agentJsonObject.getInt("pageSize").intValue());
/* 339 */       return ResDataUtils.resetSuccessJson(cpuStates);
/* 340 */     } catch (Exception e) {
/* 341 */       logger.error("aagent查询根据ip查询系统负载监控数据列表错误", e);
/* 342 */       this.logInfoService.save("agent查询根据ip查询系统负载监控数据列表错误", e.toString(), "1");
/* 343 */       return ResDataUtils.resetErrorJson(e.toString());
/*     */     } 
/*     */   }
/*     */ }


/* Location:              /Users/zhangyongxin/soft-install/wgcloud/wgcloud-v3.3.5/server/bank/wgcloud-server-release.jar!/BOOT-INF/classes/com/wgcloud/controller/SystemInfoOpenController.class
 * Java compiler version: 8 (52.0)
 * JD-Core Version:       1.1.3
 */